4be4ed0b280d92aacf1a30b88008258884a14301,src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java,LettuceConnection,pfAdd,#number[]#number[]#,4359

Before Change



		try {
			if (isPipelined()) {
				if (values.length == 1) {
					pipeline(new LettuceResult(getAsyncConnection().pfadd(key, values[0])));
				} else {
					pipeline(
							new LettuceResult(getAsyncConnection().pfadd(key, values[0], LettuceConverters.subarray(values, 1))));
				}
				return null;
			}
			if (isQueueing()) {
				if (values.length == 1) {
					transaction(new LettuceTxResult(getConnection().pfadd(key, values[0])));
				} else {
					transaction(
							new LettuceTxResult(getConnection().pfadd(key, values[0], LettuceConverters.subarray(values, 1))));
				}

				return null;
			}

			if (values.length == 1) {
				return getConnection().pfadd(key, values[0]);
			}

			return getConnection().pfadd(key, values[0], LettuceConverters.subarray(values, 1));
		} catch (Exception ex) {
			throw convertLettuceAccessException(ex);
		}

After Change


	 * @see org.springframework.data.redis.connection.HyperLogLogCommands#pfAdd(byte[], byte[][])
	 */
	@Override
	public Long pfAdd(byte[] key, byte[]... values) {

		Assert.notEmpty(values, "PFADD requires at least one non 'null' value.");
		Assert.noNullElements(values, "Values for PFADD must not contain 'null'.");

		try {
			if (isPipelined()) {
				RedisHLLAsyncCommands<byte[], byte[]> asyncConnection = getAsyncConnection();
				pipeline(new LettuceResult(asyncConnection.pfadd(key, values)));
				return null;
			}